<?php
class JdTopClient
{
	public $appkey;

	public $secretKey;
	
	public $accessToken;

	//	public $gatewayUrl = "https://router.jd.com/api";
	public $gatewayUrl = "https://api.jd.com/routerjson";

	public $format = "json";

	public $connectTimeout;

	public $readTimeout;

	/** 是否打开入参check**/
	public $checkRequest = true;

	protected $signMethod = "md5";

	protected $apiVersion = "1.0";

	protected $sdkVersion = "top-sdk-php-20150308";

	public $_CachePath ;

	public $_method = "";

	public $_saveCache = false;
	
	
	public function __construct(){
	    
	    vendor('jd.ResultSet');
	    vendor('jd.RequestCheckUtil');
	    $this->_CachePath = BASE_PATH . "/runtime/JdAPI/";
	}
	
	protected function generateSign($params)
	{
		ksort($params);
		$stringToBeSigned = $this->secretKey;
		foreach ($params as $k => $v)
		{
			if("@" != substr($v, 0, 1))
			{
				$stringToBeSigned .= "$k$v";
			}
		}
		unset($k, $v);
		$stringToBeSigned .= $this->secretKey;
		return strtoupper(md5($stringToBeSigned));
	}

	public function saveCacheData ($id,$result){
	    if(!$this->_saveCache) return;
		$idkey = substr($id,0,2);
		if (!is_dir($this->_CachePath)) {
			mkdir($this->_CachePath);
		}
		if (!is_dir($this->_CachePath .$this->_method)) {
		  mkdir($this->_CachePath .$this->_method);
		}
		if (!is_dir($this->_CachePath .$this->_method.'/'.$idkey)) {
		  mkdir($this->_CachePath .$this->_method.'/'.$idkey);
		}
		$filepath = $this->_CachePath .$this->_method.'/'.$idkey;
		if (is_dir($filepath)) {
		  $filename = $filepath .'/'.$id .'.cache';
		  @file_put_contents($filename,$result);
		}
	}
    
	public function getCacheData ($id){
		$idkey = substr($id,0,2);
		$filename = $this->_CachePath .$this->_method .'/'.$idkey .'/'.$id .'.cache';
		if(file_exists($filename)){
			return @file_get_contents($filename);
		}
		return false;
	}

	public function curl($url, $postFields = null)
	{
		$ch = curl_init();
		curl_setopt($ch, CURLOPT_URL, $url);
	//	curl_setopt($ch, CURLOPT_FAILONERROR, false);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
		if ($this->readTimeout) {
			curl_setopt($ch, CURLOPT_TIMEOUT, $this->readTimeout);
		}
		if ($this->connectTimeout) {
			curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $this->connectTimeout);
		}
		//https 请求
		if(strlen($url) > 5 && strtolower(substr($url,0,5)) == "https" ) {
			curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
			curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
		}

		if (is_array($postFields) && 0 < count($postFields))
		{
			$postBodyString = "";
			$postMultipart = false;
			foreach ($postFields as $k => $v)
			{
				if("@" != substr($v, 0, 1))//判断是不是文件上传
				{
					$postBodyString .= "$k=" . urlencode($v) . "&"; 
				}
				else//文件上传用multipart/form-data，否则用www-form-urlencoded
				{
					$postMultipart = true;
				}
			}
			unset($k, $v);
			curl_setopt($ch, CURLOPT_POST, true);
			if ($postMultipart)
			{
				curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
			}
			else
			{
				$header = array("content-type: application/x-www-form-urlencoded; charset=UTF-8");
				curl_setopt($ch,CURLOPT_HTTPHEADER,$header);
				curl_setopt($ch, CURLOPT_POSTFIELDS, substr($postBodyString,0,-1));
			}
		}
		$reponse = curl_exec($ch);
		
		if (curl_errno($ch))
		{
			throw new Exception(curl_error($ch),0);
		}
		else
		{
			$httpStatusCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
			if (200 !== $httpStatusCode)
			{
				throw new Exception($reponse,$httpStatusCode);
			}
		}
		curl_close($ch);
		return $reponse;
	}

	protected function logCommunicationError($apiName, $requestUrl, $errorCode, $responseTxt)
	{
		$localIp = isset($_SERVER["SERVER_ADDR"]) ? $_SERVER["SERVER_ADDR"] : "CLI";
		//exit(rtrim(TOP_SDK_WORK_DIR, '\\/') . '/' . "logs/top_comm_err_" . $this->appkey . "_" . date("Y-m-d") . ".log");
		$logger = new JdTopLogger;
		$logger->conf["log_file"] = $this->_CachePath . "itaoke/top_comm_err_" . $this->appkey . "_" . date("Y-m-d") . ".log";
		$logger->conf["separator"] = "^_^";
		$logData = array(
		date("Y-m-d H:i:s"),
		$apiName,
		$this->appkey,
		$localIp,
		PHP_OS,
		$this->sdkVersion,
		$requestUrl,
		$errorCode,
		str_replace("\n","",$responseTxt)
		);
		$logger->log($logData);
	}

	public function execute($request, $session = null)
	{
		$this->_method = $request['method'];
		$this->_CachePath = $this->_CachePath . "runtime/JdAPI/";
		$result =  new ResultSet(); 
		//组装系统参数
		$sysParams["app_key"] = $this->appkey;
		$sysParams["v"] = $this->apiVersion;
		$sysParams["format"] = $this->format;
		$sysParams["sign_method"] = $this->signMethod;
		$sysParams["method"] = $this->_method;
		$sysParams["timestamp"] = date("Y-m-d H:i:s");
		if (null != $session)
		{
			$sysParams["access_token"] = $session;
		}

		//获取业务参数
	    unset($request['method']);
		//$apiParams = $request;
		//$apiParams['param_json'] = json_encode($request);
	    $apiParams['360buy_param_json'] = json_encode($request);
		//签名
		$sysParams["sign"] = $this->generateSign(array_merge($apiParams, $sysParams));

		//系统参数放入GET请求串
		$requestUrl = $this->gatewayUrl . "?";
		foreach ($sysParams as $sysParamKey => $sysParamValue)
		{
			$requestUrl .= "$sysParamKey=" . urlencode($sysParamValue) . "&";
		}
		$requestUrl = substr($requestUrl, 0, -1);
		$cacheid = md5($this->createStrParam($apiParams));
		if (!$resp = $this->getCacheData($cacheid)) {
			//发起HTTP请求
			$logger = new JdTopLogger;
			$logger->conf["log_file"] = $this->_CachePath . "itaoke_logs/logs_" . $this->appkey . "_" . date("Y-m-d") . ".log";
			$logger->log(array(
				$this->appkey,
				$this->_method,
				date("Y-m-d H:i:s")
			));
			try{
				$resp = $this->curl($requestUrl, $apiParams);
				if(strlen($resp)>150){
					$this->saveCacheData($cacheid,$resp);
				}
			}catch (Exception $e){
				$this->logCommunicationError($sysParams["method"],$requestUrl,"HTTP_ERROR_" . $e->getCode(),$e->getMessage());
				$result->code = $e->getCode();
				$result->msg = $e->getMessage();
				return $result;
			}
		}else{
			if(strlen($resp)>100){
				$this->saveCacheData($cacheid,$resp);
			}
		}
		//解析TOP返回结果
		$respWellFormed = false;
		if ("json" == $this->format)
		{
			$respObject = json_decode($resp);
			if (null !== $respObject)
			{
				$respWellFormed = true;
				foreach ($respObject as $propKey => $propValue)
				{
					$respObject = $propValue;
				}
			}
		}
		else if("xml" == $this->format)
		{
			$respObject = @simplexml_load_string($resp);
			if (false !== $respObject)
			{
				$respWellFormed = true;
			}
		}

		//返回的HTTP文本不是标准JSON或者XML，记下错误日志
		if (false === $respWellFormed)
		{
			$this->logCommunicationError($sysParams["method"],$requestUrl,"HTTP_RESPONSE_NOT_WELL_FORMED",$resp);
			$result->code = 0;
			$result->msg = "HTTP_RESPONSE_NOT_WELL_FORMED";
			return $result;
		}

		//如果TOP返回了错误码，记录到业务错误日志中
		if (isset($respObject->code))
		{
			$logger = new JdTopLogger;
			$logger->conf["log_file"] = $this->_CachePath . "itaoke_logs/logs_" . $this->appkey . "_" . date("Y-m-d") . ".log";
			$logger->log(array(
				date("Y-m-d H:i:s"),
				$resp
			));
		}
		return $respObject;
	}

	public function createStrParam ($paramArr){
        $strParam = array();
        foreach ($paramArr as $key =>$val) {
            if ($key != ''&&$val != '') {
                $strParam []= $key .'='.urlencode($val);
            }
        }
        return implode('&',$strParam);
	}

	public function exec($paramsArray)
	{
		if (!isset($paramsArray["method"]))
		{
			trigger_error("No api name passed");
		}
		$inflector = new LtInflector;
		$inflector->conf["separator"] = ".";
		$requestClassName = ucfirst($inflector->camelize(substr($paramsArray["method"], 7))) . "Request";
		if (!class_exists($requestClassName))
		{
			trigger_error("No such api: " . $paramsArray["method"]);
		}

		$session = isset($paramsArray["session"]) ? $paramsArray["session"] : null;

		$req = new $requestClassName;
		foreach($paramsArray as $paraKey => $paraValue)
		{
			$inflector->conf["separator"] = "_";
			$setterMethodName = $inflector->camelize($paraKey);
			$inflector->conf["separator"] = ".";
			$setterMethodName = "set" . $inflector->camelize($setterMethodName);
			if (method_exists($req, $setterMethodName))
			{
				$req->$setterMethodName($paraValue);
			}
		}
		return $this->execute($req, $session);
	}
	public function load_api($api_name){
		Vendor('taobao.request.'.$api_name);
		return new $api_name;
	}
}

class JdTopLogger
{
	public $conf = array(
		"separator" => "\t",
		"log_file" => ""
	);
	
	public $_saveLog = false;
	private $fileHandle;

	protected function getFileHandle()
	{
		if (null === $this->fileHandle)
		{
			if (empty($this->conf["log_file"]))
			{
				trigger_error("no log file spcified.");
			}
			$logDir = dirname($this->conf["log_file"]);
			if (!is_dir($logDir))
			{
				mkdir($logDir, 0777, true);
			}
			$this->fileHandle = fopen($this->conf["log_file"], "a");
		}
		return $this->fileHandle;
	}

	public function log($logData)
	{
		if(!$this->_saveLog)	return ;
		if ("" == $logData || array() == $logData)
		{
			return false;
		}
		if (is_array($logData))
		{
			$logData = implode($this->conf["separator"], $logData);
		}
		$logData = $logData. "\n";
		fwrite($this->getFileHandle(), $logData);
	}
}
